package com.hulk.mq;

/**
 * 功能概要：消息产生,提交到队列中去 
 * @author CUIJIAJUN
 * @date   2017年1月6日
 * 
 */
import javax.annotation.Resource;  

import org.junit.Test;
import org.junit.runner.RunWith;
import org.slf4j.Logger;  
import org.slf4j.LoggerFactory;  
import org.springframework.amqp.core.AmqpTemplate;  
import org.springframework.amqp.core.Message;
import org.springframework.amqp.core.MessageProperties;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.stereotype.Service;  
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = { "classpath:MessageConsumer_topic.xml"})
public class MessageConsumer_topic {  
  
	@Test
    public void testRabbitMq() throws Exception {
       Thread.sleep(40000);
       System.out.println("启动消费者");
    }
}  